type golang.org/x/net/http2.serverConn
82 uses
golang.org/x/net/http2 (current package)
server.go#L86: testHookGetServerConn func(*serverConn)
server.go#L88: testHookOnPanic func(sc *serverConn, panicVal interface{}) (rePanic bool)
server.go#L183: activeConns map[*serverConn]struct{}
server.go#L186: func (s *serverInternalState) registerConn(sc *serverConn) {
server.go#L195: func (s *serverInternalState) unregisterConn(sc *serverConn) {
server.go#L227: conf.state = &serverInternalState{activeConns: make(map[*serverConn]struct{})}
server.go#L399: func (s *Server) serveConn(c net.Conn, opts *ServeConnOpts, newf func(*serverConn)) {
server.go#L405: sc := &serverConn{
server.go#L549: func (sc *serverConn) rejectConn(err ErrCode, debug string) {
server.go#L557: type serverConn struct {
server.go#L625: func (sc *serverConn) maxHeaderListSize() uint32 {
server.go#L633: func (sc *serverConn) curOpenStreams() uint32 {
server.go#L647: sc *serverConn
server.go#L671: func (sc *serverConn) Framer() *Framer { return sc.framer }
server.go#L672: func (sc *serverConn) CloseConn() error { return sc.conn.Close() }
server.go#L673: func (sc *serverConn) Flush() error { return sc.bw.Flush() }
server.go#L674: func (sc *serverConn) HeaderEncoder() (*hpack.Encoder, *bytes.Buffer) {
server.go#L678: func (sc *serverConn) state(streamID uint32) (streamState, *stream) {
server.go#L705: func (sc *serverConn) setConnState(state http.ConnState) {
server.go#L711: func (sc *serverConn) vlogf(format string, args ...interface{}) {
server.go#L717: func (sc *serverConn) logf(format string, args ...interface{}) {
server.go#L765: func (sc *serverConn) condlogf(err error, format string, args ...interface{}) {
server.go#L784: func (sc *serverConn) canonicalHeader(v string) string {
server.go#L820: func (sc *serverConn) readFrames() {
server.go#L852: func (sc *serverConn) writeFrameAsync(wr FrameWriteRequest, wd *writeData) {
server.go#L862: func (sc *serverConn) closeAllStreamsOnConnClose() {
server.go#L869: func (sc *serverConn) stopShutdownTimer() {
server.go#L876: func (sc *serverConn) notePanic() {
server.go#L891: func (sc *serverConn) serve(conf http2Config) {
server.go#L1011: case func(*serverConn):
server.go#L1037: func (sc *serverConn) handlePingTimer(lastFrameReadTime time.Time) {
server.go#L1078: func (sc *serverConn) onSettingsTimer() { sc.sendServeMsg(settingsTimerMsg) }
server.go#L1079: func (sc *serverConn) onIdleTimer() { sc.sendServeMsg(idleTimerMsg) }
server.go#L1080: func (sc *serverConn) onReadIdleTimer() { sc.sendServeMsg(readIdleTimerMsg) }
server.go#L1081: func (sc *serverConn) onShutdownTimer() { sc.sendServeMsg(shutdownTimerMsg) }
server.go#L1083: func (sc *serverConn) sendServeMsg(msg interface{}) {
server.go#L1096: func (sc *serverConn) readPreface() error {
server.go#L1152: func (sc *serverConn) writeDataFromHandler(stream *stream, data []byte, endStream bool) error {
server.go#L1199: func (sc *serverConn) writeFrameFromHandler(wr FrameWriteRequest) error {
server.go#L1219: func (sc *serverConn) writeFrame(wr FrameWriteRequest) {
server.go#L1283: func (sc *serverConn) startFrameWrite(wr FrameWriteRequest) {
server.go#L1340: func (sc *serverConn) wroteFrame(res frameWriteResult) {
server.go#L1408: func (sc *serverConn) scheduleFrameWrite() {
server.go#L1456: func (sc *serverConn) startGracefulShutdown() {
server.go#L1479: func (sc *serverConn) startGracefulShutdownInternal() {
server.go#L1483: func (sc *serverConn) goAway(code ErrCode) {
server.go#L1497: func (sc *serverConn) shutDownIn(d time.Duration) {
server.go#L1502: func (sc *serverConn) resetStream(se StreamError) {
server.go#L1513: func (sc *serverConn) processFrameFromReader(res readFrameResult) bool {
server.go#L1570: func (sc *serverConn) processFrame(f Frame) error {
server.go#L1623: func (sc *serverConn) processPing(f *PingFrame) error {
server.go#L1647: func (sc *serverConn) processWindowUpdate(f *WindowUpdateFrame) error {
server.go#L1679: func (sc *serverConn) processResetStream(f *RSTStreamFrame) error {
server.go#L1698: func (sc *serverConn) closeStream(st *stream, err error) {
server.go#L1745: func (sc *serverConn) processSettings(f *SettingsFrame) error {
server.go#L1773: func (sc *serverConn) processSetting(s Setting) error {
server.go#L1808: func (sc *serverConn) processSettingInitialWindowSize(val uint32) error {
server.go#L1836: func (sc *serverConn) processData(f *DataFrame) error {
server.go#L1933: func (sc *serverConn) processGoAway(f *GoAwayFrame) error {
server.go#L1999: func (sc *serverConn) processHeaders(f *MetaHeadersFrame) error {
server.go#L2110: func (sc *serverConn) upgradeRequest(req *http.Request) {
server.go#L2164: func (sc *serverConn) checkPriority(streamID uint32, p PriorityParam) error {
server.go#L2175: func (sc *serverConn) processPriority(f *PriorityFrame) error {
server.go#L2183: func (sc *serverConn) newStream(id, pusherID uint32, state streamState) *stream {
server.go#L2219: func (sc *serverConn) newWriterAndRequest(st *stream, f *MetaHeadersFrame) (*responseWriter, *http.Request, error) {
server.go#L2288: func (sc *serverConn) newWriterAndRequestNoBody(st *stream, rp httpcommon.ServerRequestParam) (*responseWriter, *http.Request, error) {
server.go#L2324: func (sc *serverConn) newResponseWriter(st *stream, req *http.Request) *responseWriter {
server.go#L2345: func (sc *serverConn) scheduleHandler(streamID uint32, rw *responseWriter, req *http.Request, handler func(http.ResponseWriter, *http.Request)) error {
server.go#L2365: func (sc *serverConn) handlerDone() {
server.go#L2390: func (sc *serverConn) runHandler(rw *responseWriter, req *http.Request, handler func(http.ResponseWriter, *http.Request)) {
server.go#L2431: func (sc *serverConn) writeHeaders(st *stream, headerData *writeResHeaders) error {
server.go#L2463: func (sc *serverConn) write100ContinueHeaders(st *stream) {
server.go#L2480: func (sc *serverConn) noteBodyReadFromHandler(st *stream, n int, err error) {
server.go#L2490: func (sc *serverConn) noteBodyRead(st *stream, n int) {
server.go#L2501: func (sc *serverConn) sendWindowUpdate32(st *stream, n int32) {
server.go#L2506: func (sc *serverConn) sendWindowUpdate(st *stream, n int) {
server.go#L2530: conn *serverConn
server.go#L2586: conn *serverConn
server.go#L2815: w.rws.conn.sendServeMsg(func(sc *serverConn) {
server.go#L2841: w.rws.conn.sendServeMsg(func(sc *serverConn) {
server.go#L3162: func (sc *serverConn) startPush(msg *startPushRequest) {
server.go#L3306: func (sc *serverConn) countError(name string, err error) error {